//package com.jay.base.thread.book;
//
//import java.util.concurrent.*;
//
///**
// * Created by caoyuan7 on 2019/8/7.
// */
//public class RejectThreadPoolDemo {
//    public static class MyTask implements Runnable{
//
//        public void run() {
//            System.out.println(System.currentTimeMillis() + ":Thread ID:" + Thread.currentThread().getId());
//            try {
//                Thread.sleep(100);
//            }catch (InterruptedException e){
//                e.printStackTrace();
//            }
//        }
//    }
//
//    public static void main(String args[]) throws InterruptedException{
//        MyTask task = new MyTask();
//        ExecutorService es = new ThreadPoolExecutor(5, 5, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>()
//                , Executors.defaultThreadFactory(), new RejectedExecutionHandler() {
//            @Override
//            public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
//                System.out.println(r.toString()+" is discard");
//            }
//        });
//        for(int i = 0;i<Integer.MAX_VALUE;i++){
//            es.submit(task);
//            Thread.sleep(10);
//        }
//    }
//}